package org.test.mq.common;

import com.alibaba.rocketmq.common.message.MessageExt;

public interface IMessageProcessor {
	/**
	 * 处理消息
	 * @param messageExt
	 * @return
	 */
	public boolean handleMessage(MessageExt messageExt);
}
